package com.biz.primus.ms.coupon.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 优惠券配置Spring Stream Processor
 *
 * @author david-liu
 */
public interface CouponPropertyProcessor {

    String SYNC_PROPERTY = "sync_property";

    String SYNC_RECEIVED = "sync_received";

    @Input(SYNC_PROPERTY)
    SubscribableChannel syncCouponPropertyMessageSubscriber();

    @Output(SYNC_RECEIVED)
    MessageChannel syncCouponPropertyMessagePublisher();

}
